package com.xcc.cloud.stream.sink;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 自定义mq的管道输出
 */
public interface MqMessageSink {

    String IN_PUT = "input";
    String IN_PUT1 = "input1";
    String IN_PUT2 = "input2";

    @Input(IN_PUT)
    SubscribableChannel input();

    @Input(IN_PUT1)
    SubscribableChannel input1();

    @Input(IN_PUT2)
    SubscribableChannel input2();

}
